package org.example.springrocketmq.myrocketmq.Consumer;

import org.apache.rocketmq.client.consumer.MessageSelector;
import org.apache.rocketmq.spring.annotation.MessageModel;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
import org.springframework.stereotype.Component;

@Component
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "my-consumer-group",messageModel = MessageModel.BROADCASTING,selectorExpression = "tagA || tagB")
public class Consumer {
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}
